c29a324704358755467854594f24edfba5264ef6,CLI/src/main/java/com/gigaspaces/cloudify/shell/installer/LocalhostGridAgentBootstrapper.java,LocalhostGridAgentBootstrapper,startManagementOnLocalhostAndWaitInternal,#String[]#number#TimeUnit#boolean#,387
Before Change
connectionLogs.supressConnectionErrors();
try {
if (!noWebServices) {
ManagementWebServiceInstaller webuiInstaller = new ManagementWebServiceInstaller();
webuiInstaller.setAdmin(agent.getAdmin());
webuiInstaller.setVerbose(verbose);
webuiInstaller.setProgress(progressInSeconds,TimeUnit.SECONDS);
webuiInstaller.setMemory(WEBUI_MEMORY_IN_MB, MemoryUnit.MEGABYTES);
webuiInstaller.setPort(WEBUI_PORT);
webuiInstaller.setWarFile(new File(WEBUI_FILE));
webuiInstaller.setServiceName(WEBUI_NAME);
webuiInstaller.setManagementZone(MANAGEMENT_GSA_ZONE);
try {
webuiInstaller.install();
}
catch (ProcessingUnitAlreadyDeployedException e) {
if (verbose) {
logger.info("Service " + WEBUI_NAME + " already installed");
}
}
if (waitForWebUi)
waitForManagementServices.add(webuiInstaller);
else
webuiInstaller.logServiceLocation();
ManagementWebServiceInstaller restInstaller = new ManagementWebServiceInstaller();
restInstaller.setAdmin(agent.getAdmin());
After Change
}
waitForManagementProcesses(agent, ShellUtils.millisUntil(TIMEOUT_ERROR_MESSAGE, end), TimeUnit.MILLISECONDS);
if (!noWebServices) {
connectionLogs.supressConnectionErrors();
try {
ManagementWebServiceInstaller webuiInstaller = new ManagementWebServiceInstaller();
webuiInstaller.setAdmin(agent.getAdmin());
webuiInstaller.setVerbose(verbose);
webuiInstaller.setProgress(progressInSeconds,TimeUnit.SECONDS);
webuiInstaller.setMemory(WEBUI_MEMORY_IN_MB, MemoryUnit.MEGABYTES);
webuiInstaller.setPort(WEBUI_PORT);
webuiInstaller.setWarFile(new File(WEBUI_FILE));
webuiInstaller.setServiceName(WEBUI_NAME);
webuiInstaller.setManagementZone(MANAGEMENT_GSA_ZONE);
try {
webuiInstaller.install();
}
catch (ProcessingUnitAlreadyDeployedException e) {
if (verbose) {
logger.info("Service " + WEBUI_NAME + " already installed");
}
}
ManagementWebServiceInstaller restInstaller = new ManagementWebServiceInstaller();
restInstaller.setAdmin(agent.getAdmin());
restInstaller.setProgress(progressInSeconds, TimeUnit.SECONDS);
restInstaller.setVerbose(verbose);
restInstaller.setMemory(REST_MEMORY_IN_MB, MemoryUnit.MEGABYTES);
restInstaller.setPort(REST_PORT);
restInstaller.setWarFile(new File(REST_FILE));
restInstaller.setServiceName(REST_NAME);
restInstaller.setManagementZone(MANAGEMENT_GSA_ZONE);
try {
restInstaller.install();
}
catch (ProcessingUnitAlreadyDeployedException e) {
if (verbose) {
logger.info("Service " + REST_NAME + " already installed");
}
}
//assuming eager mode, PU installs on this even if already installed
if (waitForWebUi) {
webuiInstaller.waitForProcessingUnitInstance(agent, ShellUtils.millisUntil(TIMEOUT_ERROR_MESSAGE, end), TimeUnit.MILLISECONDS);
} else {
// log an estimation of the Webui URL
webuiInstaller.logServiceLocation();
}
URL restUrl = restInstaller.waitForProcessingUnitInstance(agent, ShellUtils.millisUntil(TIMEOUT_ERROR_MESSAGE, end), TimeUnit.MILLISECONDS);